package cn.codecang.mall.common.task;

import org.apache.kafka.clients.admin.NewTopic;
import org.springframework.kafka.core.KafkaTemplate;
import org.springframework.scheduling.annotation.Async;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import org.springframework.transaction.annotation.Transactional;

import javax.annotation.Resource;
import java.util.Date;

/**
 * ScheduledTask
 *
 * @author xiaoluo
 * @date 2023/6/6 19:17
 */
@Component
public class ScheduledTask {
//    private final KafkaTemplate<String, String> kafka;
//    @Resource(name = "initTopic")
//    private NewTopic newTopic;
//
//
//    public ScheduledTask(KafkaTemplate<String, String> kafka) {
//        this.kafka = kafka;
//    }
//
//    @Scheduled(cron = "* * * * * *")
//    @Async
//    public void test() {
//        kafka.send(newTopic.name(), 1,"5", "test " + new Date());
//    }
//
//    @Scheduled(cron = "* * * * * *")
//    @Async
//    public void test1() {
//        kafka.send(newTopic.name(), 2,"6", "test1 " + new Date());
//    }
//
//    @Scheduled(cron = "* * * * * *")
//    @Async
//    public void test2() {
//        kafka.send(newTopic.name(), 3,"7", "test2 " + new Date());
//    }
//
//    @Scheduled(cron = "* * * * * *")
//    @Async
//    public void test3() {
//        kafka.send(newTopic.name(), 4,"8", "test3 " + new Date());
//    }
}
